import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.spark.serializer.KryoRegistrator;

import com.esotericsoftware.kryo.Kryo;

 class MyRegistrator extends KryoRegistrator {

    @Override def registerClasses( arg0:Kryo) {
        arg0.register(classOf[ConsumerRecord[String,String] ]);
    }

}  